package com.ahcloud.edas.common.kafka;

import com.ahcloud.edas.common.thread.ServiceThread;

/**
 * @program: edas
 * @description:
 * @author: YuKai Fan
 * @create: 2024/6/7 09:49
 **/
public abstract class BaseConsumer extends ServiceThread {

    private final String env;
    private final String consumerGroup;

    public final static String LINK = "-";

    protected BaseConsumer(String env, String consumerGroup) {
        this.env = env;
        this.consumerGroup = consumerGroup;
    }

    public String getSuffix() {
        return env;
    }

    public String getConsumerGroup() {
        return consumerGroup;
    }
}

